package org.jeecg.modules.demo.test.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.constant.CacheConstant;
import org.jeecg.common.system.query.QueryGenerator;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.demo.test.entity.JeecgDemo;
import org.jeecg.modules.demo.test.mapper.JeecgDemoMapper;
import org.jeecg.modules.demo.test.service.IJeecgDemoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * @Description: jeecg 测试demo
 * @Author: jeecg-boot
 * @Date: 2018-12-29
 * @Version: V1.0
 */
@Service
public class JeecgDemoServiceImpl extends ServiceImpl<JeecgDemoMapper, JeecgDemo> implements IJeecgDemoService {
    @Autowired
    JeecgDemoMapper jeecgDemoMapper;

    /**
     * 事务控制在service层面
     * 加上注解：@Transactional，声明的方法就是一个独立的事务（有异常DB操作全部回滚）
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void testTran() {
        JeecgDemo pp = new JeecgDemo();
        pp.setAge(1111);
        pp.setName("测试事务  小白兔 1");
        jeecgDemoMapper.insert(pp);

        JeecgDemo pp2 = new JeecgDemo();
        pp2.setAge(2222);
        pp2.setName("测试事务  小白兔 2");
        jeecgDemoMapper.insert(pp2);
        //自定义异常
        Integer.parseInt("hello");

        JeecgDemo pp3 = new JeecgDemo();
        pp3.setAge(3333);
        pp3.setName("测试事务  小白兔 3");
        jeecgDemoMapper.insert(pp3);
        return;
    }


    /**
     * 缓存注解测试： redis
     */
    @Override
    @Cacheable(cacheNames = CacheConstant.TEST_DEMO_CACHE, key = "#id")
    public JeecgDemo getByIdCacheable(String id) {
        JeecgDemo t = jeecgDemoMapper.selectById(id);
        System.err.println("---未读缓存，读取数据库---");
        System.err.println(t);
        return t;
    }


    @Override
    public IPage<JeecgDemo> queryListWithPermission(int pageSize, int pageNo) {
        Page<JeecgDemo> page = new Page<>(pageNo, pageSize);
        //编程方式，获取当前请求的数据权限规则SQL片段
        String sql = QueryGenerator.installAuthJdbc(JeecgDemo.class);
        return this.baseMapper.queryListWithPermission(page, sql);
    }

    @Override
    public String getExportFields() {
        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
        //权限配置列导出示例
        //1.配置前缀与菜单中配置的列前缀一致
        List<String> noAuthList = new ArrayList<>();
        List<String> exportFieldsList = new ArrayList<>();
        String permsPrefix = "testdemo:";
        //查询配置菜单有效字段
        List<String> allAuth = this.jeecgDemoMapper.queryAllAuth(permsPrefix);
        //查询已授权字段
        List<String> userAuth = this.jeecgDemoMapper.queryUserAuth(sysUser.getUsername(), permsPrefix);
        //列出未授权字段
        for (String perms : allAuth) {
            if (!userAuth.contains(perms)) {
                noAuthList.add(perms.substring(permsPrefix.length()));
            }
        }
        //实体类中字段与未授权字段比较，列出需导出字段
        Field[] fileds = JeecgDemo.class.getDeclaredFields();
        List<Field> list = new ArrayList(Arrays.asList(fileds));
        for (Field field : list) {
            if (!noAuthList.contains(field.getName())) {
                exportFieldsList.add(field.getName());
            }
        }
        return exportFieldsList != null && exportFieldsList.size() > 0 ? String.join(",", exportFieldsList) : "";
    }

    @Override
    public List<String> getCreateByList() {
        return jeecgDemoMapper.getCreateByList();
    }

}
